d0460ff23c3ce3dea35f616c5c7a242d121edf27,core/client/src/main/java/alluxio/client/netty/NettyUnderFileSystemFileWriter.java,NettyUnderFileSystemFileWriter,write,#InetSocketAddress#number#number#number[]#number#number#,62

Before Change


    try {
      channel = BlockStoreContext.acquireNettyChannel(address, mClientBootstrap);
      listener = new SingleResponseListener();
      ((ClientHandler) channel.pipeline().last()).addListener(listener);
      ChannelFuture channelFuture = channel.writeAndFlush(
          new RPCFileWriteRequest(ufsFileId, fileOffset, length,
              new DataByteArrayChannel(source, offset, length))).sync();

After Change


    try {
      channel = BlockStoreContext.acquireNettyChannel(address, mClientBootstrap);
      listener = new SingleResponseListener();
      channel.pipeline().get(ClientHandler.class).addListener(listener);
      ChannelFuture channelFuture = channel.writeAndFlush(
          new RPCFileWriteRequest(ufsFileId, fileOffset, length,
              new DataByteArrayChannel(source, offset, length))).sync();